package cn.itcast.up.up_web.controller;

import cn.itcast.up.common.HdfsTools;
import cn.itcast.up.up_web.bean.HttpResult;
import cn.itcast.up.up_web.bean.dto.ModelDto;
import cn.itcast.up.up_web.bean.dto.TagDto;
import cn.itcast.up.up_web.bean.dto.TagModel;
import cn.itcast.up.up_web.service.TagService;
import cn.itcast.up.up_web.utils.Codes;
import org.apache.tomcat.util.http.fileupload.IOUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
import java.util.UUID;

/**
 * 标签的控制层
 */
@RestController
public class TagController {

    //导入Service的依赖
    @Autowired
    private TagService tagService;

    /**
     * 添加123级标签.
     * [{"label":"一级标签名称","name":"电商","level":"1"},
     * {"label":"二级标签名称","name":"京东商城","level":"2"},
     * {"label":"三级标签名称","name":"人口属性","level":"3"}]
     * @RequestBody 将请求的Json转换为对象
     */
    @PutMapping("tags/relation") //限制请求方式为Put
    public void addTags(@RequestBody List<TagDto> list){
        //将list保存到数据库,将list交给service进行处理
        tagService.saveAll(list);
    }


    //查询123级标签列表
    @GetMapping("tags")
    public HttpResult<List<TagDto>> findTags(Long pid){
        //去调用service,开始获取数据
        List<TagDto> list = tagService.findTagsByPid(pid);
        //如何将list集合返回呢?
        //如果出现错误,给一个状态信息,
        //404 页面找不到
        //500 后台出错了
       return new HttpResult<List<TagDto>>(Codes.SUCCESS, "成功", list);
    }
    //添加4级标签和模型
    @PutMapping("tags/model")
    public void saveTagModel(@RequestBody TagModel tagModel){
        tagService.saveTagModel(tagModel);
    }

    //获取4级标签模型数据
    @GetMapping("tags/model")
    public HttpResult<List<TagModel>> getTagModel(Long pid) {
        //Pid是3级的ID
        List<TagModel> list = tagService.findAllTagModel(pid);
        return new HttpResult<List<TagModel>>(Codes.SUCCESS, "成功", list);
    }

    //添加5级标签
    @PutMapping("tags/data")
    public HttpResult putData(@RequestBody TagDto tagDto){
        tagService.addDataTag(tagDto);
        return new HttpResult(Codes.SUCCESS, "添加成功", null);
    }

    /**
     * 文件上传
     * @param file 负责接收请求携带的文件,这里必须叫file
     * @return
     */
    @PostMapping("tags/upload")
    public HttpResult uploadFile(MultipartFile file) throws IOException {
        //接收文件
        file.getContentType();//文件的类型
        file.getOriginalFilename();//文件的名字
        file.getSize();//上传文件的大小
        //将文件缓存到本地
        InputStream inputStream = file.getInputStream();
        IOUtils.copy(inputStream, new FileOutputStream(new File("a.jar")));
        //将本地缓存上传到HDFS
        //构建一个上传的路径.路径不能写死.
        String filename = UUID.randomUUID().toString() + ".jar";
        String path = "/tmp/jars/" + filename;
        //开始上传
        HdfsTools.build().uploadLocalFile2HDFS("a.jar", path);
        //将HDFS的文件路径返回给前端
        return new HttpResult<String>(Codes.SUCCESS, "成功", "hdfs://bd001:8020" + path);
    }




}
